﻿using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Channels;

namespace JTActiveSafety.Gateway.InMemoryMQ
{
    public class JTActiveSafetyMsgChannel
    {
        private Channel<(string, byte[])> Channel { get;}

        public JTActiveSafetyMsgChannel()
        {
            Channel = System.Threading.Channels.Channel.CreateUnbounded<(string, byte[])>();
        }

        public ChannelReader<(string, byte[])> Output => Channel.Reader;
        public ChannelWriter<(string, byte[])> Input => Channel.Writer;
    }
}
